package com.wgy.day41JDBC.JDBC管理事务;

import com.wgy.day41JDBC.抽取JDBC工具类.JDBCUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/*
JDBC控制事务:
1.事务:如果一个包含多个步骤的业务操作,被事务管理,那么这些操作要么同时成功,要么同时失败.
2.操作: 1.开启事务
       2.提交事务
       3.回滚事务

3.使用Connection对象来管理事务
     1.开启事务:setAutoCommit(boolean autoCommit):调用该方法设置参数为false,即开启事务
               在执行sql之前开启事务
     2.提交事务:commit():
               当所有sql都被执行完毕后提交事务
     3.回滚事务:rollback():
               在catch中回滚事务
*/
public class Demo12JDBC {
    public static void main(String[] args) {
        Connection conn=null;
        PreparedStatement pstmt1=null;
        PreparedStatement pstmt2=null;

        try {//1.获取连接
           conn = JDBCUtils.getConnection();
           //开启事务
            conn.setAutoCommit(false);

           //2.定义sql,张三账户-500,李四账户+500
            String sql1="update account set balance=balance-? where id=?";
            String sql2="update account set balance=balance-? where id=?";
            //3.获取执行sql对象
            pstmt1 = conn.prepareStatement(sql1);
            pstmt2 = conn.prepareStatement(sql2);
            //4.设置参数 给?号赋值
            pstmt1.setDouble(1,500);
            pstmt1.setInt(2,1);
            pstmt2.setDouble(1,500);
            pstmt2.setInt(2,2);
            //5.执行sql
           pstmt1.executeUpdate();
           //手动制造异常
            int i=3/0;
           pstmt2.executeUpdate();
           //没有问题提交事务
            conn.commit();

        } catch (Exception throwables) {
            //出现问题 回滚事务
            try {
                if (conn!=null){
                conn.rollback();
            }

            } catch (SQLException e) {
                e.printStackTrace();
            }

            throwables.printStackTrace();
        }finally {
            //6.释放资源
            JDBCUtils.close(pstmt1,conn);
            JDBCUtils.close(pstmt2,null);
        }
    }
}
